#ifndef WORKER_FUN
#define WORKER_FUN

#include "proto/internal.pb.h"

void workerThread(const internal::TaskList* tasks, int offset);
void consumeThread(const internal::InputOperation* resultTypes, int offset);

#endif
